/* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements.  See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License.  You may obtain a copy of the License at
*
*     http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/


/*************************************************************************
 * File: testservice.cpp
 *************************************************************************
 *\author: starlove
 *************************************************************************/

#include "testservice.h"

CTestService::CTestService(ISocket *pSocket)
{
	m_pSocket = pSocket;
	m_raw_sck = INVALID_SOCKET;
}

void CTestService::OnConnected(SOCKET s, sockaddr *pSelfAddr, sockaddr *pRemoteAddr, IPeer *&pPeer)
{
	sockaddr_in *pAddr = (sockaddr_in *)pRemoteAddr;
	//printf(">>> Peer %s:%d connected\n", inet_ntoa(pAddr->sin_addr), ntohs(pAddr->sin_port));

	void *p = g_peer_allocator.allocate();
	if (!p)
	{
		printf(">>> Accept client %s:%d fail. Create client-object fail!\n", inet_ntoa(pAddr->sin_addr), ntohs(pAddr->sin_port));
		m_pSocket->Close(s);
		return;
	}
	pPeer = new(p)CTestPeer(m_pSocket, s);
	pPeer->SetDataType(m_data_tp);
}

void CTestService::OnError(SOCKET s)
{
	printf(">>> Service Socket %d has error\n", s);
	Destory();
}

// void CTestService::OnEvent(LPEVENT ev, int event_sets)
// {
// 	CService::OnEvent(ev, event_sets);
// }
